package com.atguigu.flink.chapter05.source;

import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;


public class Flink02_Source_File {
    public static void main(String[] args) throws Exception {
        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
        // 传递文件路径： 可以说相对路径也可以说绝对路径
        /*env
           .readTextFile("hdfs://hadoop162:8020/input/words.txt")
           .print();*/
        env
           .readTextFile("input/words.txt")
           .print();
        env.execute("Flink02_Source_File");
    }

}
